#include"../mqserver/mq_connection.hpp"


int main(){
    mq::ConnectionManager::ptr cmp = std::make_shared<mq::ConnectionManager>();
    cmp->openConnection(mq::ConsumerManager::ptr(),
        muduo::net::TcpConnectionPtr(),
        mq::ProtobufCodecPtr(),
        std::make_shared<mq::Virtualhost>("host1","./data/message","./data/db_file"),mq::ThreadPool::ptr());
    return 0;
}